package thread;

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;

public class demo30 {
    public static void main(String[] args) throws InterruptedException {
        BlockingQueue<String> queue = new LinkedBlockingQueue<>(3);
        BlockingQueue<String> queue2 = new ArrayBlockingQueue<>(10);
        

        //入队列和出队列
        // queue.put("aaa");
        // System.out.println("添加一个元素");
        // queue.put("aaa");
        // System.out.println("添加一个元素");
        // queue.put("aaa");
        // System.out.println("添加一个元素");
        // queue.put("aaa");
        // System.out.println("添加一个元素");
        // queue.put("aaa");
        // System.out.println("添加一个元素");
        // String s = queue.take();
        // System.out.println(s);

        //获取队列元素
        String s = queue.take();
        System.out.println("获取到的元素：" + s);
    }
}
